package com.cn.mq.receiver;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Component;

import com.cn.mq.config.AmqpConfig;
import com.cn.mq.message.Message;

@Component
public class ReceiverTopic {
	@RabbitListener(queues = AmqpConfig.QUEUE_TOP_IC_A, containerFactory="rabbitListenerContainerFactory")
    public void process(@Payload Message msg) {  
       System.out.println("ReceiverTopic接收消息："+msg.getId());
    }
}
